package org.liuwei.concucrent.base07;

import java.util.concurrent.CompletableFuture;
/**
 * 
* @Title: AskThread.java 
* @Package org.liuwei.concucrent.base07 
* @Description: TODO(完成后得到通知) 
* @author 刘伟  15818570028@163.com   
* @date 2016年8月28日 下午4:06:34 
* @version V1.0
 */
public class CompletableFutureTest implements Runnable {
	CompletableFuture<Integer> re = null;

	public CompletableFutureTest(CompletableFuture<Integer> re) {
		this.re = re;
	}

	public void run() {
		int myRe = 0;
		try {
			System.out.println("开始等待。。。11111");
			myRe = re.get() * re.get();
			System.out.println("恩，接到数据 我也完成了=======3333");
		} catch (Exception e) {
		}
		System.out.println(myRe);
	}

	public static void main(String[] args) throws InterruptedException {
		final CompletableFuture<Integer> future = new CompletableFuture<Integer>();
		new Thread(new CompletableFutureTest(future)).start();
		// 模拟长时间的计算过程
		Thread.sleep(1000);
		// 告知完成结果
		System.out.println("完成了=======22222");
		future.complete(60);
	}
}